#include "Consumer.h"  
#include <iostream>
using namespace zbus;
using namespace std;

int main_consumer(int argc, char* argv[]) {  
	Logger::configDefaultLogger(0, LOG_INFO);   

	Broker broker("localhost:15555");

	Consumer c(&broker, "MyTopic"); 
	c.messageHander = [](Message* msg, MqClient* client) {
		msg->print();
		delete msg;
	};  
	c.start();  


	broker.join(); 
	return 0;
}